package com.zheng.flink.study.dataset.datasource;

import org.apache.flink.api.java.ExecutionEnvironment;

/**
 * Created by zhengbo on 2019/12/12.
 */
public class CsvDataSource {

    public static void main(String[] args) throws Exception {

        ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();

        env.readCsvFile("file:///D:/etc/flink/dataSetCsv_test.csv")
                .types(String.class, String.class, String.class, String.class).print();

    }
}
